/*!
 * \file rocketmq_core.h
 *
 * \brief 共通定义
 *
 * All Rights Reserved Copyright (C) 2014 broada,Co.,Ltd.\n
 * 共通使用的宏和结构体
 *
 * \version 1.0
 * \author jikw
 * \date 2017/4/10
 *
 */

#ifndef _ROCKETMQ_CORE_H_
#define _ROCKETMQ_CORE_H_

#include "conntrack.h"
#include "module.h"

#define ROCKETMQ_HASH_SIZE    10    //哈希桶的最大尺寸
#define ROCKETMQ_TIMEOUT      5*60   //单位秒

int rocketmq_detect(Conntrack *p_st_conn, Apm_packet *p_st_packet);
int rocketmq_analysis(Conntrack *p_st_conn, Apm_packet *p_st_packet, Frhash_header *p_st_hash_report);
int rocketmq_session_destroy(void *p_private_session);
void rocketmq_list_node_free(Frlist_node *p_st_node);

#endif